package org.geektimes.reactive.reactor;

import org.reactivestreams.Subscriber;
import org.reactivestreams.Subscription;

/**
 * TODO description.
 *
 * @author leo
 * @date 2021/8/25
 * @since 1.0.0
 */
public class ReceiveSubscriber implements Subscriber<String> {

    private final Subscriber<String> subscriber;

    private boolean complete;



    public ReceiveSubscriber(Subscriber<String> subscriber){
        this.subscriber = subscriber;
    }

    @Override
    public void onSubscribe(Subscription s) {
        this.subscriber.onSubscribe(s);
    }

    @Override
    public void onNext(String s) {

    }

    @Override
    public void onError(Throwable t) {

    }

    @Override
    public void onComplete() {

    }
}
